package com.czk.springboot.reactive.reactor.sink;

import reactor.core.publisher.Flux;

/**
 * 自定义流中的元素处理方式
 */
public class HandleDemo {

    public static void main(String[] args) {

        Flux<Object> flux = Flux.range(0, 10)
                // 自定义流的处理规则
                // handle后，流中可以有不同类型的数
                .handle((value, sink) -> {
                    System.out.println("得到的值" + value);
                    value = value * 2;
                    sink.next(value);
                });
        flux.log().subscribe();
    }

}
